package com.cailu.receiver.config;

import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

import com.cailu.common.constant.DelaySenderEessageCommon;

/**
 * @author cailu
 * @filename DelaySenderConfigReceiver
 * @description 延迟消费 配置在消息上
 * @date 2020/3/30 18:00
 */
@Component
public class DelaySenderEessageReceiver {

	/**
	 * 功能描述  监听 在【消息上】 延迟消费
	 * @param str 内容
	 * @return void
	 * @author cailu
	 * @date 2020/3/31 15:14
	 */
	@RabbitListener(queues = DelaySenderEessageCommon.DELAY_EXCHANGE_QUEUE_NAME)
	public void processQueue(String str) {
		System.out.println("Receive---delay_exchange_queue_name:========================:" + str.toString());
	}


}
